4284413d2901d2772356e7b4d104739f92127137,flex/jps-plugin/src/com/intellij/jps/flex/build/JpsBuiltInFlexCompilerHandler.java,JpsBuiltInFlexCompilerHandler,scheduleInputReading,#,151

Before Change


  }

  private void scheduleInputReading() {
    SharedThreadPool.getInstance().executeOnPooledThread(new Runnable() {
      public void run() {
        final StringBuilder buffer = new StringBuilder();
        while (true) {
          final DataInputStream dataInputStream = myDataInputStream;
          if (dataInputStream != null) {
            try {
              buffer.append(dataInputStream.readUTF());

              int index;
              while ((index = buffer.indexOf("\n")) > -1) {
                final String line = buffer.substring(0, index);
                buffer.delete(0, index + 1);
                handleInputLine(line);
              }
            }
            catch (IOException e) {
              if (dataInputStream == myDataInputStream) {
                stopCompilerProcess();
              }
              break;
            }
          }
          else {
            break;
          }
        }
      }
    });
  }

  private synchronized void handleInputLine(final String line) {

After Change


  }

  private void scheduleInputReading() {
    SharedThreadPool.getInstance().executeOnPooledThread(() -> {
      final StringBuilder buffer = new StringBuilder();
      while (true) {
        final DataInputStream dataInputStream = myDataInputStream;
        if (dataInputStream != null) {
          try {
            buffer.append(dataInputStream.readUTF());

            int index;
            while ((index = buffer.indexOf("\n")) > -1) {
              final String line = buffer.substring(0, index);
              buffer.delete(0, index + 1);
              handleInputLine(line);
            }
          }
          catch (IOException e) {
            if (dataInputStream == myDataInputStream) {
              stopCompilerProcess();
            }
            break;
          }
        }
        else {
          break;
        }
      }
    });
  }

  private synchronized void handleInputLine(final String line) {